package com.example.rabbitmq.test.init;

import com.example.rabbitmq.test.processors.SystemMesageProcessor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

@EnableBinding({SystemMesageProcessor.class})
@Slf4j
public class SystemMessage {

    @StreamListener(SystemMesageProcessor.INPUT)
    public void receive(String message) {
        log.info("收到系统消息：{}", message);
    }
}
